package com.lxy.cloud.mqtt.client.service.impl;

import com.lxy.cloud.mqtt.client.constant.SystemConstant;
import com.lxy.cloud.mqtt.client.model.dto.A2FileDownloadDTO;
import com.lxy.cloud.mqtt.client.model.dto.BaseMqttDTO;
import com.lxy.cloud.mqtt.client.model.dto.MqttEventDTO;
import com.lxy.cloud.mqtt.client.service.AbstractMessageProcessService;
import org.springframework.stereotype.Service;

/**
 * @Author: lxy
 * @Date: 2020/9/7 15:02
 * @Desc: 处理收到车端的A2文件通知逻辑
 */
@Service(value = SystemConstant.A2FILE_NOTIFY)
public class A2FileNotifyProcessServiceImpl extends AbstractMessageProcessService<MqttEventDTO<A2FileDownloadDTO>> {
    @Override
    protected MqttEventDTO<A2FileDownloadDTO> convertMessage(BaseMqttDTO request) {
        return null;
    }

    @Override
    protected void process(MqttEventDTO<A2FileDownloadDTO> acpMessage) {
        System.out.println("acpMessage = " + acpMessage);
    }

}
